package com.gitee.Transformation

import org.apache.flink.api.scala.ExecutionEnvironment

object DistinctTest {
  def main(args: Array[String]): Unit = {
    val env: ExecutionEnvironment = ExecutionEnvironment.getExecutionEnvironment
    import org.apache.flink.api.scala._
    env.setParallelism(1)
    case class User(id: String, name: String)
    val lineData: DataSet[(String, Int)] = env.fromElements(("java",1),("jva",1),("java",1))

    lineData.distinct(0).print()
  }

}
